﻿using System;
using System.Threading;
using Common.Logging;

namespace Out.TaskRunner.Consumers
{
    //public class HospCommonNotice : IConsumer
    //{
    //    private static readonly ILog Logger = LogManager.GetLogger(typeof(HospCommonNotice));

    //    public void Start(CancellationToken ct)
    //    {
    //        if (ct.IsCancellationRequested)
    //        {
    //            return;
    //        }

    //        using (var consumer = new HospCommonNoticeConsumer())
    //        {
    //            consumer.Subscribe((id, count, dt, msg) =>
    //            {
    //                Console.WriteLine("{0} - 第 {1} 次接收", DateTime.Now, count);
    //                return false;
    //            } );

    //            while (true)
    //            {
    //                if (ct.IsCancellationRequested)
    //                {
    //                    break;
    //                }

    //                Thread.Sleep(50);
    //            }
    //        }            
    //    }
    //}
}